package learnrxjava.examples;
import java.util.concurrent.TimeUnit;

import rx.Observable;
import rx.Scheduler;
import rx.schedulers.Schedulers;


public class ZipInterval {


    public static void main(String... args) {
        Observable<String> data = Observable.just("one", "two", "three", "four", "five");
        Observable.zip(data,Observable.interval(5200, TimeUnit.MILLISECONDS),
                (d, t) ->  d + " " + t
        ).toBlocking().forEach(System.out::println);
    }
}
